package com.gxgeek.order.message;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author gaoxing
 * @create 2018-03-28 下午4:25
 */
public interface StreamClient {
    String INPUT = "myMessage";
    String INPUT2 = "myMessage2";

    @Input(INPUT)
    SubscribableChannel input();
    @Output(INPUT2)
    MessageChannel output();

//    @Input(INPUT2)
//    SubscribableChannel input2();
//    @Output(INPUT2)
//    MessageChannel output2();
}
